
package com.up.kafka.sender;

import com.up.kafka.productor.KafkaProducer;
import com.up.kafka.productor.MessageRecord;


import java.io.IOException;

/**
 * @author: baiMl
 * @title: ByteArraySender
 * @projectName: 海联技术中台V2.0
 * @depart 软件事业部
 * @description:
 * @date: 2022/4/25 8:53
 */
public class ByteArraySender extends BasicSender {


    public ByteArraySender(KafkaProducer<byte[]> producer) {
        super(producer);
    }

    @Override
    protected <V> MessageRecord<Object> wrapperMsg(String key, V message, String topic, Integer partition) throws IOException {
//        byte[] serialize = MsgPackSerializer.serialize(message);
        return wrapperMessageRecord(key,message,topic,partition);
    }
}
